Module cubist_proxy::transformer

transformer: a (stream/sink) <-> (stream/sink) adapter

Modules

eth_creds

Ethereum credential handling

Functions

canon_request

Create a Request by canonicalizing a URI

canon_request_stream

Canonicalize the URIs in a stream of requests by applying canon_request to each, where uri provides the scheme and authority for the resulting URI.

convert

Apply a pair of synchronous conversions to a Pair, returning another Pair

convert_fut

Apply a pair of future-returning conversions to a Pair, returning another Pair

copy

Given a Pair, return two new Pairs that are duplicates of the original

debug

Logs all messages into and out of the pair, printing the label along with it.

errors_to_sink

Given a Pair, reroute all Err() values from its Stream into its Sink. Returns a new Pair whose Stream outputs all Ok() values and whose Sink connects to the input Pair’s sink.

errors_to_stream

Convert the error type of a Pair, returning a new Pair.

json

Parses a stream of JSON strings into any type T which implements deserialize

switch

Given a Pair and a predicate, return two pairs, one for True and one for False

switch_convert_stream

Route values from an input stream to one of two output sinks according to a function that converts the value to either the type of the send_ok stream or the type of the send_err stream.

switch_stream

Route values from an input stream to one of two output sinks according to a predicate