 //
 
 import Foundation
-
+/*
+struct DatedBunch {
+	fileprivate let issueQueue: DispatchQueue
+	var lastSend = Date()
+	var messages : [String: MQTTMessage]
+	public func on(message: MQTTMessage)
+	}
+}
+*/
 public protocol MQTTBatchingSessionDelegate: class {
-    func mqttDidReceive(messages: [MQTTMessage], from session: MQTTBatchingSession)
+    func mqttDidReceive(message: MQTTMessage, from session: MQTTBatchingSession)
     func mqttConnected(_ changed: Bool, for: MQTTBatchingSession, error: Error?)
 }
 

    public func disconnect() {
        self.session = nil
        issueQueue.async {
            self.delegate?.mqttConnected(false, for: self, error: error)
        }
    }
}

			clientID: connectParams.clientID,
			cleanSession: connectParams.cleanSession,
			keepAlive: connectParams.keepAlive,
			connectionTimeout: connectParams.timeout,
			useSSL: connectParams.useSSL)
    }
}
