Class DataMultiplexingInbox
- java.lang.Object
-
- de.unistuttgart.isw.sfsc.commonjava.zmq.pubsubsocketpair.inputmanagement.data.DataMultiplexingInbox
-
- All Implemented Interfaces:
NotThrowingAutoCloseable,DataMultiplexer,AutoCloseable
public class DataMultiplexingInbox extends Object implements DataMultiplexer, NotThrowingAutoCloseable
-
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description Handleadd(Predicate<com.google.protobuf.ByteString> filter, BiConsumer<com.google.protobuf.ByteString,com.google.protobuf.ByteString> handler)voidclose()static DataMultiplexingInboxcreate(ReactiveSocket.Inbox inbox)voidstart()
-
-
-
Method Detail
-
create
public static DataMultiplexingInbox create(ReactiveSocket.Inbox inbox)
-
start
public void start()
-
add
public Handle add(Predicate<com.google.protobuf.ByteString> filter, BiConsumer<com.google.protobuf.ByteString,com.google.protobuf.ByteString> handler)
- Specified by:
addin interfaceDataMultiplexer
-
close
public void close()
- Specified by:
closein interfaceAutoCloseable- Specified by:
closein interfaceNotThrowingAutoCloseable
-
-