java.lang.Object
- de.unistuttgart.isw.sfsc.commonjava.zmq.pubsubsocketpair.inputmanagement.forwarder.ForwardingInbox

All Implemented Interfaces:: NotThrowingAutoCloseable, Forwarder, AutoCloseable

public class ForwardingInbox
extends Object
implements Forwarder, NotThrowingAutoCloseable

All Methods Static Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`Handle`	`addListener(Consumer<List<byte[]>> listener)`
`void`	`close()`
`static ForwardingInbox`	`create(ReactiveSocket.Inbox inbox)`
`void`	`start()`

public static ForwardingInbox create(ReactiveSocket.Inbox inbox)

public Handle addListener(Consumer<List<byte[]>> listener)

Class ForwardingInbox