Module: NNQ

Defined in:

lib/nnq/cli.rb,
lib/nnq/cli/bus.rb,
lib/nnq/cli/pair.rb,
lib/nnq/cli/pipe.rb,
lib/nnq/cli/term.rb,
lib/nnq/cli/config.rb,
lib/nnq/cli/pub_sub.rb,
lib/nnq/cli/req_rep.rb,
lib/nnq/cli/version.rb,
lib/nnq/cli/formatter.rb,
lib/nnq/cli/push_pull.rb,
lib/nnq/cli/cli_parser.rb,
lib/nnq/cli/base_runner.rb,
lib/nnq/cli/pipe_worker.rb,
lib/nnq/cli/socket_setup.rb,
lib/nnq/cli/ractor_helpers.rb,
lib/nnq/cli/transient_monitor.rb,
lib/nnq/cli/surveyor_respondent.rb,
lib/nnq/cli/expression_evaluator.rb

Defined Under Namespace

Modules: CLI

Class Attribute Summary

• .incoming_proc ⇒ Proc^? readonly

  Registered incoming message transform.

• .outgoing_proc ⇒ Proc^? readonly

  Registered outgoing message transform.

Class Method Summary

• .incoming {|Array<String>| ... } ⇒ Proc

  Registers an incoming message transform (used by -r scripts).

• .outgoing {|Array<String>| ... } ⇒ Proc

  Registers an outgoing message transform (used by -r scripts).

Class Attribute Details

.incoming_proc ⇒ Proc^? (readonly)

Returns registered incoming message transform.

Returns:

• (Proc, nil) —

  registered incoming message transform

# File 'lib/nnq/cli.rb', line 29

def incoming_proc
  @incoming_proc
end

.outgoing_proc ⇒ Proc^? (readonly)

Returns registered outgoing message transform.

Returns:

• (Proc, nil) —

  registered outgoing message transform

# File 'lib/nnq/cli.rb', line 27

def outgoing_proc
  @outgoing_proc
end

Class Method Details

.incoming {|Array<String>| ... } ⇒ Proc

Registers an incoming message transform (used by -r scripts).

Yields:

• (Array<String>) —

  1-element message array after receiving

Returns:

• (Proc)

# File 'lib/nnq/cli.rb', line 41

def incoming(&block) = @incoming_proc = block

.outgoing {|Array<String>| ... } ⇒ Proc

Registers an outgoing message transform (used by -r scripts).

Yields:

• (Array<String>) —

  1-element message array before sending

Returns:

• (Proc)

# File 'lib/nnq/cli.rb', line 35

def outgoing(&block) = @outgoing_proc = block