 				expect(error).to(beNil())
 				expect(completed) == false
 
-				sendNext(sink, 1)
+				sink.sendNext(1)
 				expect(values) == [ 1 ]
-				sendNext(sink, 2)
-				sendNext(sink, 3)
+				sink.sendNext(2)
+				sink.sendNext(3)
 				expect(values) == [ 1, 2, 3 ]
 
-				sendCompleted(sink)
+				sink.sendCompleted()
 				expect(completed) == true
 			}
 

					expect(counter).to(equal(0))

					producer.start()
					sendNext(otherSignalSink, 1)
					expect(counter) == 1

					producer.start()
					sendNext(otherSignalSink, 2)
					expect(counter) == 2
				}



				expect(error).to(beNil())

				sink.sendError(sentError)
				expect(error) == sentError
			}
		}
