aboutsummaryrefslogtreecommitdiffstats
path: root/exercises/concurrent
diff options
context:
space:
mode:
Diffstat (limited to 'exercises/concurrent')
-rw-r--r--exercises/concurrent/concurrent3/main_test.go43
1 files changed, 43 insertions, 0 deletions
diff --git a/exercises/concurrent/concurrent3/main_test.go b/exercises/concurrent/concurrent3/main_test.go
new file mode 100644
index 0000000..4a7cf33
--- /dev/null
+++ b/exercises/concurrent/concurrent3/main_test.go
@@ -0,0 +1,43 @@
+// concurrent3
+// Make the tests pass!
+
+// I AM NOT DONE
+package main_test
+
+import (
+ "bytes"
+ "fmt"
+ "testing"
+)
+
+func TestSendAndReceive(t *testing.T) {
+ var buf bytes.Buffer
+
+ messages := make(chan string)
+ sendAndReceive(&buf, messages)
+
+ got := buf.String()
+ want := "Hello World"
+
+ if got != want {
+ t.Errorf("got %q want %q", got, want)
+ }
+}
+
+func sendAndReceive(buf *bytes.Buffer, messages chan string) {
+ go func() {
+ messages <- "Hello"
+ messages <- "World"
+ close(messages)
+ }()
+
+ greeting := <-messages
+ fmt.Fprint(buf, greeting)
+
+ // Here we just receive the first message
+ // Consider using a for-range loop to iterate over the messages
+ _, ok := <-messages
+ if !ok {
+ fmt.Fprint(buf, "Channel is closed")
+ }
+}