DynamoDBStreamReadable prematurely emits `end`

[asprouse]

DynamoDBStreamReadable prematurely emits end which causes the serverless-offline-dynamodb-streams plugin to close it's writable. This means that when the plugin is used with TRIM_HORIZON it will only fire handlers on sls offline start.

Looks like this PR to fix LATEST starting point might have broken this: https://github.com/CoorpAcademy/serverless-plugins/pull/37

[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.