akka/akka-core

Sink with resource management

Open

#21,526 opened on Sep 22, 2016

View on GitHub
 (12 comments) (1 reaction) (0 assignees)Scala (3,547 forks)batch import
1 - triagedhelp wantedt:stream

Repository metrics

Stars
 (13,277 stars)
PR merge metrics
 (Avg merge 8d 19h) (10 merged PRs in 30d)

Description

Source has unfoldResource() and unfoldResourceAsync(). It does open a resource, read and close. It would be useful if Sink had a similar method, which does open, write and close. It may be named as Sink.foreachResource().

Contributor guide

Research direction
Study the existing Source.unfoldResource and unfoldResourceAsync implementations. Design a similar pattern for Sink that opens a resource, writes elements, and closes. Consider error handling and resource cleanup. Provide a pull request with the new method and tests.
Tech stack
scala
Domain
backendbackend api design
Issue type
Feature
DifficultyEstimated implementation difficulty for a new contributor, from 1 for very small changes to 5 for expert-level work.
3
Estimated timeA rough time range for an experienced contributor to investigate, implement, test, and prepare a pull request.
1-3 hours
Activity statusHow available the issue appears right now: fresh, active, stale, blocked, or waiting on maintainer input.
Active
ClarityHow clearly the issue explains the expected change, acceptance criteria, and next step.
Mostly clear
Prerequisites
ScalaAkka Streams
Newbie friendlinessA 1-100 score estimating how approachable this issue is for first-time contributors.
60