 			startHeatBeatTimer(timeInterval: timeInterval)
 		}
 
-		onSocketOpen?()
+		onOpen?()
 	}
 
 	private func webSocketDidReceiveMessage(messageStr: String) {

				)
			}

			onSocketMessage?(result: .Success(message))
		} catch let error as NSError {
			webSocketDidError(error)
			onSocketMessage?(result: .Failure(error))
		}
	}
	


		}

		onClose?(code: code, reason: reason, wasClean: wasClean)
	}

	private func webSocketDidError(error: NSError) {
		queue.suspended = true
		discardHeartBeatTimer()

		onError?(error: error)

		webSocketDidClose(
			code: error.code,
