importer

type AccountingServiceImpl struct {
	goat_grpc.UnimplementedAccountingServiceServer // warning: struct of size 72 bytes could be of size 64 bytes
	// contains filtered or unexported fields
}

type RecordStream interface {
	// ReceiveIdentifier receives client identifier from given stream.
	// If the first message is not client identifier, errNonFirstClientIdentifier is returned
	ReceiveIdentifier() (string, error)

	// Receive receives the next record from the stream.
	// If there is no more records in the stream, io.EOF is returned.
	// If an identifier is received, errNonFirstClientIdentifier is returned.
	Receive() (wrapper.RecordWrapper, error)

	// Close closes the stream
	Close() error
}