chore: reorganize the extension package (#155)

reugn · Jan 31, 2025 · 05bdc46 · 05bdc46
1 parent 209586b
commit 05bdc46
Show file tree

Hide file tree

Showing 7 changed files with 43 additions and 40 deletions.
diff --git a/examples/fs/.gitignore → examples/file/.gitignore b/examples/fs/.gitignore → examples/file/.gitignore
@@ -1,2 +1,2 @@
-fs
+file
 out.txt
diff --git a/examples/fs/in.txt → examples/file/in.txt b/examples/fs/in.txt → examples/file/in.txt
diff --git a/examples/fs/main.go → examples/file/main.go b/examples/fs/main.go → examples/file/main.go
diff --git a/extension/fs.go → extension/file.go b/extension/fs.go → extension/file.go
diff --git a/extension/net.go → extension/network.go b/extension/net.go → extension/network.go
diff --git a/extension/sink_ignore.go b/extension/sink_ignore.go
@@ -0,0 +1,42 @@
+package extension
+
+import "github.com/reugn/go-streams"
+
+// IgnoreSink represents a simple outbound connector that discards
+// all elements of a stream.
+type IgnoreSink struct {
+	in chan any
+}
+
+var _ streams.Sink = (*IgnoreSink)(nil)
+
+// NewIgnoreSink returns a new IgnoreSink connector.
+func NewIgnoreSink() *IgnoreSink {
+	ignoreSink := &IgnoreSink{
+		in: make(chan any),
+	}
+
+	// asynchronously process stream data
+	go ignoreSink.process()
+
+	return ignoreSink
+}
+
+func (ignore *IgnoreSink) process() {
+	for {
+		_, ok := <-ignore.in
+		if !ok {
+			break
+		}
+	}
+}
+
+// In returns the input channel of the IgnoreSink connector.
+func (ignore *IgnoreSink) In() chan<- any {
+	return ignore.in
+}
+
+// AwaitCompletion is a no-op for the IgnoreSink.
+func (ignore *IgnoreSink) AwaitCompletion() {
+	// no-op
+}
diff --git a/extension/std.go → extension/sink_stdout.go b/extension/std.go → extension/sink_stdout.go
@@ -44,42 +44,3 @@ func (stdout *StdoutSink) In() chan<- any {
 func (stdout *StdoutSink) AwaitCompletion() {
 	<-stdout.done
 }
-
-// IgnoreSink represents a simple outbound connector that discards
-// all elements of a stream.
-type IgnoreSink struct {
-	in chan any
-}
-
-var _ streams.Sink = (*IgnoreSink)(nil)
-
-// NewIgnoreSink returns a new IgnoreSink connector.
-func NewIgnoreSink() *IgnoreSink {
-	ignoreSink := &IgnoreSink{
-		in: make(chan any),
-	}
-
-	// asynchronously process stream data
-	go ignoreSink.process()
-
-	return ignoreSink
-}
-
-func (ignore *IgnoreSink) process() {
-	for {
-		_, ok := <-ignore.in
-		if !ok {
-			break
-		}
-	}
-}
-
-// In returns the input channel of the IgnoreSink connector.
-func (ignore *IgnoreSink) In() chan<- any {
-	return ignore.in
-}
-
-// AwaitCompletion is a no-op for the IgnoreSink.
-func (ignore *IgnoreSink) AwaitCompletion() {
-	// no-op
-}
-Original file line number
+Diff line change
@@ -1,2 +1,2 @@
-    fs
+    file
     out.txt