PairWriter

@groovy.transform.CompileStatic
class PairWriter
extends RegulatingActor<java.util.Map<java.lang.String, java.lang.Object>>

A simple class that whose purpose is purely to paralleise writing output to a Writer.

Each message contains two attributes:

content - a String value representing the data to be written
reads - the count of reads contained in the data Each message can contain many reads and therefore potentially represents a large amount of data. Therfore the queuing on this queue should be constrained to be quite small. For example, if the buffer size is 1MB then 50 queued messages will represent 50MB of memory.
A pending count is decremented with each batch of reads written. This count needs to be incremented by the caller for it to be accurate. If this is done, the pending count will reflect how many reads are queued, waiting to be written, and thus give an estimate of how much memory is currently being consumed by buffered reads.
Authors:
Simon Sadedin

Fields
Modifiers	Name	Description
`java.util.concurrent.atomic.AtomicInteger`	`pending`

Properties
Type	Name and description
`java.io.Writer`	`out`
`int`	`written`

Constructors
Constructor and description
`PairWriter (java.io.Writer writer, int queueSize)`

Methods
Type Params	Return Type	Name and description
	`void`	`process(java.util.Map<java.lang.String, java.lang.Object> msg)`

Groovy Documentation

[Groovy] Class PairWriter