public interface BaseSubscriberBuilder<B extends BaseSubscriberBuilder<B,S,M>,S,M>
Modifier and Type | Method and Description |
---|---|
S |
build()
Creates and returns a new subscriber.
|
B |
withEndOfSubscriptionHandler(@NotNull Runnable handler)
Sets the end of subscription handler for the
subscriber.
|
B |
withIndex(long initialIndex)
Sets the initial index to use if this builder
builds an index aware subscriber.
|
B |
withIndexAware()
Sets that the subscriber built should be
an index aware subscriber.
|
B |
withTcpBufferFull(@NotNull BooleanSupplier tcpBufferFullSupplier)
Sets the tcp buffer full supplier to use for
the subscriber.
|
B |
withUsingMessage(M usingMessage)
Provides a re-usable object that will be recycled
for subscriber messages.
|
B withEndOfSubscriptionHandler(@NotNull @NotNull Runnable handler)
handler
- to use for the subscriberB withTcpBufferFull(@NotNull @NotNull BooleanSupplier tcpBufferFullSupplier)
tcpBufferFullSupplier
- to use for the subscriberB withIndexAware()
B withIndex(long initialIndex)
initialIndex
- for the subscriberB withUsingMessage(M usingMessage)
usingMessage
- to re-useS build()
Copyright © 2021. All rights reserved.