Go Streams

Easily build streamed operations in Go.

Example stream

pub := NewSlicePublisher([]int{0, 1, 2})
flow := MapFlow(func(i int) string {
	return fmt.Sprint(i)
})
sub := NewSliceSubscriber[string]()

pub.Connect(flow)
flow.Connect(sub)

stream := New(pub, flow, sub)
stream.Run()

Built in Publishers

• SlicePublisher
• more to come...

Built in Subscribers

• SliceSubscriber
• more to come...