NewAsyncMessageSink returns a pointer a new AsyncMessageSink.

WithAckBufferSize sets the ack channel buffer size.

WithAckFunc set the AckFunc callback function, which is called for each ack recieved.

WithMsgBufferSize sets the msg channel buffer size.

AsyncMessageSink wraps substrate.AsyncMessageSink and provides an interface for interaction with the underlying sink, as well as the capability to flush the message buffer.

AckFunc is a callback function executed by `Run` for each message succesfully produced.

An AsyncMessageSinkOption is a function which sets an AsyncMessageSink configuration option.