class Concurrent::Channel::Buffer::Dropping
A non-blocking, buffered buffer of fixed maximum capacity. When the maximum capacity is reached subsequent {#put} and {#offer} operations will complete but the ‘put` item will be discarded; no transfer will occur.
Public Instance Methods
Source
# File lib/concurrent-ruby-edge/concurrent/channel/buffer/dropping.rb, line 36 def blocking? false end
@!macro channel_buffer_blocking_question
Always returns ‘false`.
Private Instance Methods
Source
# File lib/concurrent-ruby-edge/concurrent/channel/buffer/dropping.rb, line 43 def ns_full? false end
@!macro channel_buffer_full_question
Source
# File lib/concurrent-ruby-edge/concurrent/channel/buffer/dropping.rb, line 48 def ns_put_onto_buffer(item) buffer.push(item) unless buffer.size == capacity end
@!macro channel_buffer_put