package fwktest

import "go-hep.org/x/hep/fwk/internal/fwktest"

Index ¶

• type InputStream
• func (stream *InputStream) Connect(ports []fwk.Port) error
• func (stream *InputStream) Disconnect() error
• func (stream *InputStream) Read(ctx fwk.Context) error
• type MyInt
• type MyStruct
• type OutputStream
• func (out *OutputStream) Connect(ports []fwk.Port) error
• func (out *OutputStream) Disconnect() error
• func (out *OutputStream) Write(ctx fwk.Context) error

Types ¶

type InputStream ¶

type InputStream struct {
	R io.Reader
	// contains filtered or unexported fields
}

func (*InputStream) Connect ¶

func (stream *InputStream) Connect(ports []fwk.Port) error

func (*InputStream) Disconnect ¶

func (stream *InputStream) Disconnect() error

func (*InputStream) Read ¶

func (stream *InputStream) Read(ctx fwk.Context) error

type MyInt ¶

type MyInt int

type MyStruct ¶

type MyStruct struct {
	I int
}

type OutputStream ¶

type OutputStream struct {
	W io.Writer
	// contains filtered or unexported fields
}

func (*OutputStream) Connect ¶

func (out *OutputStream) Connect(ports []fwk.Port) error

func (*OutputStream) Disconnect ¶

func (out *OutputStream) Disconnect() error

func (*OutputStream) Write ¶

func (out *OutputStream) Write(ctx fwk.Context) error

Source Files ¶

inputstream.go outputstream.go reducer.go svc1.go task1.go task2.go task3.go task4.go