tdlib-session-container/src/main/java/it/tdlight/reactiveapi/EventProducer.java

package it.tdlight.reactiveapi;

import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;

public interface EventProducer<K> {

	Mono<Void> sendMessages(Flux<K> eventsFlux);

	void close();
}