reformat

Author: mridul-sahu

fan_in_fixed_arguments.go

@@ -6,11 +6,13 @@ func BoringFanInFixedArguments(input1, input2 <-chan string) <-chan string {
 	go func() {
 		for {
 			select {
-			case s := <-input1: c <- s
-			case s := <-input2: c <- s
+			case s := <-input1:
+				c <- s
+			case s := <-input2:
+				c <- s
 			}
 		}
 	}()
 
 	return c
-}
+}

fan_out_all.go

@@ -1,14 +1,14 @@
 package main
 
-func FanOutAll(input <-chan string, outs... chan<- string) {
+func FanOutAll(input <-chan string, outs ... chan<- string) {
 	go func() {
 		for {
 			msg := <-input
 			for _, out := range outs {
-				go func(o chan<-string) {
+				go func(o chan<- string) {
 					o <- msg
 				}(out)
 			}
 		}
 	}()
-}
+}

generator.go

@@ -8,7 +8,7 @@ import (
 func BoringGenerator(msg string) <-chan string {
 	c := make(chan string)
 
-	go func(){
+	go func() {
 		for i := 0; ; i++ {
 			c <- fmt.Sprintf("%s %d", msg, i)
 			time.Sleep(time.Second)

receive_till_quit.go

@@ -5,7 +5,8 @@ import "fmt"
 func BoringReceiveTillQuit(input <-chan string, quit <-chan bool) {
 	for {
 		select {
-		case s := <-input: fmt.Print(s)
+		case s := <-input:
+			fmt.Print(s)
 		case <-quit:
 			fmt.Print("Oh ok that was nice talk")
 			return

send_when_available.go

@@ -7,10 +7,10 @@ import (
 
 type Request struct {
 	query string
-	data chan string
+	data  chan string
 }
 
-func SendWhenAvailable() chan<-Request {
+func SendWhenAvailable() chan<- Request {
 	r := make(chan Request)
 
 	go func(r <-chan Request) {

sequential_fan_in.go

@@ -3,7 +3,7 @@ package main
 import "fmt"
 
 type Message struct {
-	msg string
+	msg  string
 	wait chan bool
 }
 
@@ -20,7 +20,7 @@ func BoringSyncedGenerator(msg string) <-chan Message {
 	return m
 }
 
-func BoringSequentialFanIn(syncedChans... <-chan Message) <-chan string {
+func BoringSequentialFanIn(syncedChans ... <-chan Message) <-chan string {
 	c := make(chan string)
 
 	go func() {

synced_quit.go

@@ -2,10 +2,11 @@ package main
 
 import "fmt"
 
-func BoringSyncedQuit (input <-chan string, quit chan bool) {
+func BoringSyncedQuit(input <-chan string, quit chan bool) {
 	for {
 		select {
-		case s := <-input: fmt.Print(s)
+		case s := <-input:
+			fmt.Print(s)
 		case <-quit:
 			fmt.Print("Well see ya, bye")
 			quit <- true