Fix #572. Respect end in Bus.push

Author: phadej

spec/specs/bus.coffee

@@ -94,6 +94,26 @@ describe "Bacon.Bus", ->
     bus.onValue(->)
     expect(plugged).to.deep.equal(false)
 
+  it "respects end() even events comes from plugged stream", ->
+    failed = false
+    busA = new Bacon.Bus()
+    busB = new Bacon.Bus()
+    busB.onValue(-> failed = true;)
+    busB.plug(busA)
+    busB.end()
+    busA.push('foo')
+    expect(failed).to.equal(false)
+
+  it "does not plug after end(), second variant", ->
+    failed = false
+    busA = new Bacon.Bus()
+    busB = new Bacon.Bus()
+    busB.onValue(-> failed = true;)
+    busB.plug(busA)
+    busA.push('foo')
+    busB.end()
+    expect(failed).to.equal(false)
+
   it "respects end() calls before subscribers", ->
     failed = false
     bus = new Bacon.Bus()

src/bus.coffee

@@ -48,7 +48,7 @@ class Bus extends EventStream
     @sink? endEvent()
 
   push: (value) ->
-    @sink? nextEvent(value)
+    @sink? nextEvent(value) unless @ended
 
   error: (error) ->
     @sink? new Error(error)