fix:check closed in synchronized block when multi thread.

[songjinze]

Pull Request Description

Should check closed when multi thread in synchronized block so that stream won't be closed twice.

Acceptance Test

• Building the code with gradle clean build still works.

Questions

• Does this pull request break backward compatibility?

  • Yes and my commit follows the Conventional Commits Specification
  • No

• Does this pull request require other pull requests to be merged first?

  • Yes, please see #...
  • No

• Does this require an update of the documentation?

  • Yes, please see [provide details here]
  • No

[carlspring]

@songjinze ,

Thank you very much for your contribution!

Would it at all be possible to provide some sort of test case for this?

[songjinze]

@songjinze ,

Thank you very much for your contribution!

Would it at all be possible to provide some sort of test case for this?

@carlspring Just added a test for thread safe close. I'm not sure how to make a test for multi write because it may not be stable for throwing an io exception when one thread is closing and another is writing.

[steve-todorov]

Hey @songjinze ,

Sorry for our delay - we've been busy at our daytime work and had to do some pipeline fixes to allow builds to run from contributors which was why we postponed merging this for so long.

We are planning to merge this PR and release 1.0.2 at some point this week or the beginning of next. Don't worry about rebasing / updating your PR with the upstream. We'll do it for you before we merge. :)

[steve-todorov]

@songjinze thanks for your contribution! :)