node

package

v0.0.0 Latest Latest Go to latest Published: Jul 20, 2026 License: GPL-3.0 Imports: 0 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Duplex[X any] struct {
	ID string
	Ch chan X
}

func New[X any](id string, bufsize int) *Duplex[X]

func (n Duplex[X]) AsInput() Input[X]

func (n Duplex[X]) AsOutput() Output[X]

func (n Duplex[X]) Connect(o withOutput[X], i withInput[X])

func (n *Duplex[X]) Init(id string, bufsize int)

type Input[X any] struct {
	ID string
	Ch <-chan X
}

type Output[X any] struct {
	ID string
	Ch chan<- X
}