redefine stream types

[plastikfan]

The stream types have the Job embedded within them. Due to the design of go types, this gives us a problem that somethimes make working with the types difficult to understand.

If it were easy to translated between related types (specifically the channel types), we wouldn't have a problem.

Eg

If we have input and output types defined as:

type MyInput int
type MyOutput string
type MyInputJobStream boost.JobStream[MyInput]
type MyOutputJobStream boost.OutputStream[MyOutput]

we can define out work pool as:

boost.WorkerPool[MyInput, MyOutput ]

But the problem here is, if we try to use the predefined channel definitions, we find that incompatibles occur, as the type keyword introduces new incompatible types.

So, using OutputStream

type MyOutputJobStream boost.OutputStream[MyOutput]

.. is ok in isolation, but when we consider this:

func (p *WorkerPool[I, O]) Start(
	ctx context.Context,
	outputsChOut OutputStream[O],
) {
	p.run(ctx, p.private.workersJobsCh, outputsChOut)
}

this only works with:

	pool := boost.WorkerPool[MyInput, MyOutput]{}
	pool.Start(context.Background(),
		make(boost.OutputStream[MyOutput]),
	)

when in actual fact, we would rather use our custom channel type defs:

	pool.Start(context.Background(),
		make(MyOutputJobStream),
	)

which is not valid, due to incompatible types:

cannot use make(MyOutputJobStream) (value of type MyOutputJobStream) as boost.OutputStream[MyOutput] value in argument to pool.Startcompiler[InvalidChanAssign](https://pkg.go.dev/golang.org/x/tools/internal/typesinternal#InvalidChanAssign)

So MyOutputJobStream is not compatible with boost.OutputStream[MyOutput]

[plastikfan]

Actually, on the client side we can make this work by using 'type =':

type MyInputJobStream = boost.JobStream[MyInput]
type MyOutputJobStream = boost.OutputStream[MyOutput]

with these in place, we can now do:

	pool.Start(context.Background(),
		make(MyOutputJobStream),
	)

... and this works because of the '=', which doesn't introduce new types, they introduce aliases to existing type, which makes them compatible, so now MyOutputJobStream is compatible with boost.OutputStream[MyOutput]

This is a good lesson. Perhaps this should be emphasized in documentation.

[plastikfan]

so now, the purpose of this issue changes from redefining the core channel types to changing the way these types are interacted with.