io

package

v0.0.3 Latest Latest Go to latest Published: May 26, 2026 License: MIT Imports: 3 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type IOService struct {
	// contains filtered or unexported fields
}

func New(inbox Inbox, outbox Outbox, reader connection.Connection, codec app.Decoder) *IOService

func (service *IOService) Read(ctx context.Context) error

func (service *IOService) Write(ctx context.Context) error

type Inbox interface {
	Enqueue(context.Context, app.Message) error
}

type Outbox interface {
	Next(context.Context) ([]byte, error)
}