PoisonExceptionpublic class RejectableBufferedOne2AnyChannel extends java.lang.Object implements RejectableChannel
This implements a one-to-any object channel with user-definable buffering,
safe for use by a single writer and many readers. Refer to One2AnyChannel for a
description of this behaviour.
Additionally, this channel supports a reject operation. One of the readers may call
the reject method to force any current writer to abort with a
ChannelDataRejectedException (unless there is already a read which will cause
completion of the write). Subsequent read and write attempts will immediately cause a
ChannelDataRejectedException.
| Constructor and Description |
|---|
RejectableBufferedOne2AnyChannel(ChannelDataStore data)
Deprecated.
Constructs a new
RejectableBufferedOne2AnyChannel |
| Modifier and Type | Method and Description |
|---|---|
RejectableChannelInput |
in()
Deprecated.
|
RejectableChannelOutput |
out()
Deprecated.
|
public RejectableBufferedOne2AnyChannel(ChannelDataStore data)
RejectableBufferedOne2AnyChanneldata - the buffer implementation to use.public RejectableChannelInput in()
in in interface RejectableChannelpublic RejectableChannelOutput out()
out in interface RejectableChannelCopyright © 1996–2022. All rights reserved.