*
* @return void
*/
- function handleIncomingRawData ();
+ function handleIncomingDecodedData ();
/**
* Checks whether incoming decoded data is handled.
*
* @return void
*/
- function assembleRawDataToPackage ();
+ function assembleDecodedDataToPackage ();
/**
* Checks whether a new message has arrived
**************************************************************************/
/**
- * Call-back handler to handle unhandled packages. This method "explodes"
- * the string with the chunk separator from PackageFragmenter class, does
- * some low checks on it and feeds it into another queue for verification
- * and re-request for bad chunks.
+ * Call-back handler to handle unhandled package data. This method
+ * "explodes" the string with the chunk separator from PackageFragmenter
+ * class, does some low checks on it and feeds it into another queue for
+ * verification and re-request for bad chunks.
*
* @param $packageContent An array with two elements: 'raw_data' and 'error_code'
* @return void
- * @throws FinalChunkVerificationException If the final chunk does not start with 'EOP:'
*/
private function handlePackageByUnhandledPackage (array $packageContent) {
// Debug message
*
* @return void
*/
- public function handleIncomingRawData () {
+ public function handleIncomingDecodedData () {
/*
* This method should only be called if decoded raw data is pending,
* so check it again.
*
* @return void
*/
- public function assembleRawDataToPackage () {
+ public function assembleDecodedDataToPackage () {
// Make sure the raw decoded package data is handled
assert($this->isIncomingRawDataHandled());
- // Get current package content (an array with two elements; see handleIncomingRawData() for details)
+ // Get current package content (an array with two elements; see handleIncomingDecodedData() for details)
$packageContent = $this->getStackerInstance()->getNamed(self::STACKER_NAME_DECODED_HANDLED);
// Start assembling the raw package data array by chunking it
* be assembled back to a "package array". Please see NetworkPackage
* for further details (what array elements are required et cetera).
*/
- $this->getPackageInstance()->assembleRawDataToPackage();
+ $this->getPackageInstance()->assembleDecodedDataToPackage();
} elseif ($this->getPackageInstance()->isNewRawDataPending($this->getListenerPoolInstance())) {
// Raw, decoded data has been received
- $this->getPackageInstance()->handleIncomingRawData();
+ $this->getPackageInstance()->handleIncomingDecodedData();
} elseif ($this->getPackageInstance()->ifAssemblerHasPendingDataLeft()) {
// Handle any pending data from the package assembler
$this->getPackageInstance()->handleAssemblerPendingData();