Merge pull request #17 from reugn/develop

reugn · web-flow · commit 47f8f8576cb7 · 2019-10-02T20:42:41.000+03:00
document function panic conditions
diff --git a/.travis.yml b/.travis.yml
@@ -1,7 +1,7 @@
 language: go
 
 go:
-  - "1.12"
+  - "1.12.x"
 
 os:
   - linux
diff --git a/extension/kafka.go b/extension/kafka.go
@@ -47,12 +47,14 @@ func NewCommitOffset(consumer *kafka.Consumer) *CommitOffset {
 }
 
 // Via streams data through given flow
+// panics on invalid message type
 func (co *CommitOffset) Via(flow streams.Flow) streams.Flow {
 	go co.loop(flow)
 	return flow
 }
 
 // To streams data to given sink
+// panics on invalid message type
 func (co *CommitOffset) To(sink streams.Sink) {
 	co.loop(sink)
 }
diff --git a/flow/throttler.go b/flow/throttler.go
@@ -83,6 +83,7 @@ func (th *Throttler) doNotify() {
 }
 
 //prefill buffer
+//panics on Unsupported ThrottleMode
 func (th *Throttler) bufferize() {
 	defer close(th.out)
 	if th.mode == Discard {

-Original file line number
+Diff line change
@@ @@ -1,7 +1,7 @@ @@
 language: go
 go:
 -  - "1.12"
 +  - "1.12.x"
 os:
   - linux
Original file line number	Diff line number	Diff line change
`@@ -47,12 +47,14 @@ func NewCommitOffset(consumer kafka.Consumer) CommitOffset {`
`47`	`47`	`}`
`48`	`48`
`49`	`49`	`// Via streams data through given flow`
	`50`	`+// panics on invalid message type`
`50`	`51`	`func (co *CommitOffset) Via(flow streams.Flow) streams.Flow {`
`51`	`52`	`go co.loop(flow)`
`52`	`53`	`return flow`
`53`	`54`	`}`
`54`	`55`
`55`	`56`	`// To streams data to given sink`
	`57`	`+// panics on invalid message type`
`56`	`58`	`func (co *CommitOffset) To(sink streams.Sink) {`
`57`	`59`	`co.loop(sink)`
`58`	`60`	`}`
Original file line number	Diff line number	Diff line change
`@@ -83,6 +83,7 @@ func (th *Throttler) doNotify() {`
`83`	`83`	`}`
`84`	`84`
`85`	`85`	`//prefill buffer`
	`86`	`+//panics on Unsupported ThrottleMode`
`86`	`87`	`func (th *Throttler) bufferize() {`
`87`	`88`	`defer close(th.out)`
`88`	`89`	`if th.mode == Discard {`