Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

A ByteStream abstraction to represent streaming content. #298

Merged
merged 28 commits into from
Oct 11, 2018
Merged

A ByteStream abstraction to represent streaming content. #298

merged 28 commits into from
Oct 11, 2018

Commits on Oct 10, 2018

  1. Add ContentStream interface and an RxContentStream implementation. 

    All tests pass.
    @mikkokar
    mikkokar committed Oct 10, 2018
    Configuration menu
    Copy the full SHA
    c7558e9 View commit details
    Browse the repository at this point in the history

  2. Add ContentStream.map method. 

    Enable previously commented out tests.
    @mikkokar
    mikkokar committed Oct 10, 2018
    Configuration menu
    Copy the full SHA
    cf88b4a View commit details
    Browse the repository at this point in the history

  3. Add consume method to ContentStream. 

    Add ContentStream Events.
    @mikkokar
    mikkokar committed Oct 10, 2018
    Configuration menu
    Copy the full SHA
    9b2a52c View commit details
    Browse the repository at this point in the history

  4. Implement Reactive Streams RxContentPublisher.

    @mikkokar
    mikkokar committed Oct 10, 2018
    Configuration menu
    Copy the full SHA
    40a909f View commit details
    Browse the repository at this point in the history

  5. Implement ContentAggregator, RxContentConsumer for the new content st… 

    …ream

classes.
    @mikkokar
    mikkokar committed Oct 10, 2018
    Configuration menu
    Copy the full SHA
    e848df4 View commit details
    Browse the repository at this point in the history

  6. Tidy up. Add copyright notices to new files. Etc.

    @mikkokar
    mikkokar committed Oct 10, 2018
    Configuration menu
    Copy the full SHA
    e9c2d79 View commit details
    Browse the repository at this point in the history

  7. Add DiscardOperator. Rename ContentAggregator class to AggregateOpera… 

    …tor.

Add a file for ByteStream class.
    @mikkokar
    mikkokar committed Oct 10, 2018
    Configuration menu
    Copy the full SHA
    f53ed22 View commit details
    Browse the repository at this point in the history

  8. Add ByteStream and MappingOperator classes.

    @mikkokar
    mikkokar committed Oct 10, 2018
    Configuration menu
    Copy the full SHA
    7586320 View commit details
    Browse the repository at this point in the history

  9. Refactor DiscardOperator (to resemble MappingOperator). 

    Tidy up.
    @mikkokar
    mikkokar committed Oct 10, 2018
    Configuration menu
    Copy the full SHA
    198bb1b View commit details
    Browse the repository at this point in the history

  10. Disable checkstyle for RxContentPublisher and RxContentStream FSMs.

    @mikkokar
    mikkokar committed Oct 10, 2018
    Configuration menu
    Copy the full SHA
    72fab60 View commit details
    Browse the repository at this point in the history

  11. Use rxjava-reactive-streams to bridge between reactive streams and Rx… 

    …Java objects.

Use the new ByteStream class in HTTP message objects.
    @mikkokar
    mikkokar committed Oct 10, 2018
    Configuration menu
    Copy the full SHA
    4cd25eb View commit details
    Browse the repository at this point in the history

  12. Deprecate RxContentPublisher and RxContentConsumer classes in favour of 

    RxReactiveStreams bridges.
    @mikkokar
    mikkokar committed Oct 10, 2018
    Configuration menu
    Copy the full SHA
    1648e0e View commit details
    Browse the repository at this point in the history

  13. Use Reactor-Core in Styx-API HTTP message objects and API tests.

    @mikkokar
    mikkokar committed Oct 10, 2018
    Configuration menu
    Copy the full SHA
    de4e99e View commit details
    Browse the repository at this point in the history

  14. Replace DiscardOperator and MappingOperator with corresponding reactor 

    implementations.
    @mikkokar
    mikkokar committed Oct 10, 2018
    Configuration menu
    Copy the full SHA
    594e109 View commit details
    Browse the repository at this point in the history

  15. Make ByteStream to implement Publisher<Buffer> API.

    @mikkokar
    mikkokar committed Oct 10, 2018
    Configuration menu
    Copy the full SHA
    1fde3b0 View commit details
    Browse the repository at this point in the history

  16. Builder setter methods for HTTP message body.

    @mikkokar
    mikkokar committed Oct 10, 2018
    Configuration menu
    Copy the full SHA
    2b2687b View commit details
    Browse the repository at this point in the history

  17. ByteStream: Add end-of-stream future. 

    ByteStream: Rename discard() to drop().
Fix HttpResponseTest: canRemoveResponseBody.
    @mikkokar
    mikkokar committed Oct 10, 2018
    Configuration menu
    Copy the full SHA
    f11a4b9 View commit details
    Browse the repository at this point in the history

  18. ByteStream: doOnEnd action.

    @mikkokar
    mikkokar committed Oct 10, 2018
    Configuration menu
    Copy the full SHA
    4fe01a0 View commit details
    Browse the repository at this point in the history

  19. Move ByteSream into api package.

    @mikkokar
    mikkokar committed Oct 10, 2018
    Configuration menu
    Copy the full SHA
    4b676e7 View commit details
    Browse the repository at this point in the history

  20. Tidy up pom files.

    @mikkokar
    mikkokar committed Oct 10, 2018
    Configuration menu
    Copy the full SHA
    5ae13c9 View commit details
    Browse the repository at this point in the history

  21. Address code review comments. 

    Change AggregateOperator name to ByteStreamAggregator.
    @mikkokar
    mikkokar committed Oct 10, 2018
    Configuration menu
    Copy the full SHA
    65824b6 View commit details
    Browse the repository at this point in the history

  22. Hide Netty ByteBuf from the Buffer class.

    @mikkokar
    mikkokar committed Oct 10, 2018
    Configuration menu
    Copy the full SHA
    e7dbe9e View commit details
    Browse the repository at this point in the history

  23. HttpRequest/Response .toFull method: Release aggregated byte buffer a… 

    …fter

aggregation has finished.

Remove HttpMessageBodies class.
    @mikkokar
    mikkokar committed Oct 10, 2018
    Configuration menu
    Copy the full SHA
    85f2133 View commit details
    Browse the repository at this point in the history

  24. Resolved some low-hanging code review comments.

    @mikkokar
    mikkokar committed Oct 10, 2018
    Configuration menu
    Copy the full SHA
    5c54c66 View commit details
    Browse the repository at this point in the history

  25. Add Javadocs to Buffer and ByteStream classes.

    @mikkokar
    mikkokar committed Oct 10, 2018
    Configuration menu
    Copy the full SHA
    d589190 View commit details
    Browse the repository at this point in the history

  26. Add static import.

    @mikkokar
    mikkokar committed Oct 10, 2018
    Configuration menu
    Copy the full SHA
    d5bd3b8 View commit details
    Browse the repository at this point in the history

  27. Address code review comments.

    @mikkokar
    mikkokar committed Oct 10, 2018
    Configuration menu
    Copy the full SHA
    1515026 View commit details
    Browse the repository at this point in the history

  28. Improve JavaDoc for Buffer.java.

    @mikkokar
    mikkokar committed Oct 10, 2018
    Configuration menu
    Copy the full SHA
    0eb4ddc View commit details
    Browse the repository at this point in the history