Skip to content

Commit f623155

Browse files
authored
Merge pull request #87 from cschleiden/remove-unused-code
Remove converter reference on channel impl
2 parents 8a3a48c + cc460e3 commit f623155

File tree

1 file changed

+3
-10
lines changed

1 file changed

+3
-10
lines changed

internal/sync/channel.go

Lines changed: 3 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -1,9 +1,5 @@
11
package sync
22

3-
import (
4-
"github.com/cschleiden/go-workflows/internal/converter"
5-
)
6-
73
type Channel[T any] interface {
84
Send(ctx Context, v T)
95

@@ -31,16 +27,14 @@ var _ ChannelInternal[struct{}] = (*channel[struct{}])(nil)
3127

3228
func NewChannel[T any]() Channel[T] {
3329
return &channel[T]{
34-
c: make([]T, 0),
35-
converter: converter.DefaultConverter,
30+
c: make([]T, 0),
3631
}
3732
}
3833

3934
func NewBufferedChannel[T any](size int) Channel[T] {
4035
return &channel[T]{
41-
c: make([]T, 0, size),
42-
size: size,
43-
converter: converter.DefaultConverter,
36+
c: make([]T, 0, size),
37+
size: size,
4438
}
4539
}
4640

@@ -50,7 +44,6 @@ type channel[T any] struct {
5044
senders []func() T
5145
closed bool
5246
size int
53-
converter converter.Converter
5447
}
5548

5649
func (c *channel[T]) Close() {

0 commit comments

Comments
 (0)