data

Documentation

Index

• Variables
• func GetString(o Object, path string) (result string, err error)
• type Object
• type Stream
• type StreamFunc

Variables

var ErrEnd = streaming.ErrEnd

ErrEnd is the error returned by a stream when there are no more items.

var Map = streaming.Map[Object, Object]

Map creates a stream that contains the result of transforming the objects of the given stream with a mapper. Note that the actual calls to the mapper will not happen when this function is called, they will happen only when the stream is eventually consumed.

var Null = streaming.Null[Object]

Null is an empty stream of objects.

var Pour = streaming.Pour[Object]

Pour creates a stream that contains the objects in the given slice.

var Repeat = streaming.Repeat[Object]

Repeat creates a stream that repeats the same object multiple times.

var Select = streaming.Select[Object]

Select creates a new stream that only contains the items of the source stream that return true for the given selector. Note that the actual calls to the select will not happen when this function is called, they will happen only when the stream is eventually consumed.

Functions

func GetString

func GetString(o Object, path string) (result string, err error)

Types

type Object

type Object = map[string]any

Object represents an object containing a list of fields, each with a name and a value.

type Stream

type Stream = streaming.Stream[Object]

Stream is a stream of objects.

type StreamFunc

type StreamFunc = streaming.StreamFunc[Object]

StreamFunc creates an string using the given function.