package ru.kirillius.XCP.Data;

import ru.kirillius.XCP.Commons.Initializable;
import ru.kirillius.java.utils.events.EventHandler;
import tools.jackson.databind.node.ObjectNode;


public interface DataAdapter extends Initializable {
    Object send(Object value, ObjectNode properties);

    Object receive(ObjectNode properties);

    EventHandler<Object> subscribe();

    void unsubscribe(EventHandler<Object> subscription);

}