1) DataPipe.pm is also passed as DataPipe.pm[0] to the process_data closure 2) make comment how scalar is deserialized