You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@nifi.apache.org by "Gábor Gyimesi (Jira)" <ji...@apache.org> on 2022/10/03 10:10:00 UTC

[jira] [Assigned] (MINIFICPP-1648) InputStreamCallback OutputStreamCallback should use Input/OutputStream instead of BaseStream

     [ https://issues.apache.org/jira/browse/MINIFICPP-1648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Gábor Gyimesi reassigned MINIFICPP-1648:
----------------------------------------

    Assignee: Gábor Gyimesi

> InputStreamCallback OutputStreamCallback should use Input/OutputStream instead of BaseStream
> --------------------------------------------------------------------------------------------
>
>                 Key: MINIFICPP-1648
>                 URL: https://issues.apache.org/jira/browse/MINIFICPP-1648
>             Project: Apache NiFi MiNiFi C++
>          Issue Type: Improvement
>            Reporter: Martin Zink
>            Assignee: Gábor Gyimesi
>            Priority: Minor
>              Labels: MiNiFi-CPP-Hygiene
>
> The current Input/Output callback interfaces use the BaseStream instead of the respective InputStream, OutputStream.
> {code:java}
> virtual int64_t InputStreamCallback::process(const std::shared_ptr<io::BaseStream>& stream) = 0;
> virtual int64_t OutputStreamCallback::process(const std::shared_ptr<io::BaseStream>& stream) = 0;
> {code}
> Ideally it should look like this
> {code:java}
> virtual int64_t InputStreamCallback::process(const std::shared_ptr<io::InputStream>& stream) = 0;
> virtual int64_t OutputStreamCallback::process(const std::shared_ptr<io::OutputStream>& stream) = 0;
> {code}
> Without this it is impossible to create and use ReadOnly/WriteOnly streams for FlowFile IO (the BaseStream requires implementing both the Input and Output Stream interfaces)
> However there may be some feature dependent on this solution. (e.g. calling write from InputStreamCallback)
>  



--
This message was sent by Atlassian Jira
(v8.20.10#820010)