Skip to content

Commit

Permalink
Fix examples
Browse files Browse the repository at this point in the history
  • Loading branch information
urjitbhatia committed Feb 20, 2018
1 parent faa718d commit 3733173
Showing 1 changed file with 4 additions and 4 deletions.
8 changes: 4 additions & 4 deletions gopipe_example_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -26,10 +26,10 @@ func ExamplePipeline() {
// value is: 5
}

// ExamplePipelineEnqueueDequeue shows an alternative usage of Pipeline without channels directly.
// ExampleEnqueue shows an alternative usage of Pipeline without channels directly.
// Calling Enqueue will put an item in the pipeline and Dequeue will consume it. Both are blocking
// operations.
func ExamplePipelineEnqueueDequeue() {
func ExampleEnqueue() {
max := 4
dp := doublingPipe{}
sp := subtractingPipe{}
Expand All @@ -53,9 +53,9 @@ func ExamplePipelineEnqueueDequeue() {
// Dequeue with timeout: <nil>
}

// ExamplePipelineJunction shows how to create a junction and route data across
// ExampleJunction shows how to create a junction and route data across
// the junction to other pipelines
func ExamplePipelineJunction() {
func ExampleJunction() {
max := 4
p := NewBufferedPipeline(max)
rf := RoutingFunc(func(in interface{}) interface{} {
Expand Down

0 comments on commit 3733173

Please sign in to comment.