DynamoDBStreamReadable prematurely emits `end` about serverless-plugins

[godu]

@asprouse Could you give me a way to reproduce ?

[asprouse]

This happens in serverless-offline-dynamodb-streams on line 165 you can observe end being emitted by simply inserting an on call to the readable:

const readable = DynamoDBReadable(
        dynamodbStreamsClient,
        streamARN,
        assign(this.config, {
          shardId,
          limit: tableEvent.batchSize,
          iterator: tableEvent.startingPosition || 'TRIM_HORIZON'
        })
      );

      readable.on('end', () => console.log('Readable End!');

      readable.pipe(
        new Writable({
          objectMode: true,
          write: (chunk, encoding, cb) => {
            this.eventHandler(streamARN, functionName, shardId, chunk, cb);
          }
        })
      );
    }, shards);

Since you are implementing your own writable this isn't an issue here but write streams are supposed to close when end is emitted.