interop

type FallbackReaderCodec interface {
	Create(rdr io.ReadCloser, aFn service.AckFunc, details scanner.SourceDetails) (FallbackReaderStream, error)
	Close(context.Context) error
}

type FallbackReaderStream interface {
	NextBatch(ctx context.Context) (service.MessageBatch, service.AckFunc, error)
	Close(context.Context) error
}