1 /* 2 * Copyright 2022 The Android Open Source Project 3 * 4 * Licensed under the Apache License, Version 2.0 (the "License"); 5 * you may not use this file except in compliance with the License. 6 * You may obtain a copy of the License at 7 * 8 * http://www.apache.org/licenses/LICENSE-2.0 9 * 10 * Unless required by applicable law or agreed to in writing, software 11 * distributed under the License is distributed on an "AS IS" BASIS, 12 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 13 * See the License for the specific language governing permissions and 14 * limitations under the License. 15 */ 16 17 package androidx.datastore.core 18 19 import java.io.FileOutputStream 20 import java.io.OutputStream 21 22 /** Wrapper on FileOutputStream to prevent closing the underlying OutputStream. */ 23 internal class UncloseableOutputStream(val fileOutputStream: FileOutputStream) : OutputStream() { 24 writenull25 override fun write(b: Int) { 26 fileOutputStream.write(b) 27 } 28 writenull29 override fun write(b: ByteArray) { 30 fileOutputStream.write(b) 31 } 32 writenull33 override fun write(bytes: ByteArray, off: Int, len: Int) { 34 fileOutputStream.write(bytes, off, len) 35 } 36 closenull37 override fun close() { 38 // We will not close the underlying FileOutputStream until after we're done syncing 39 // the fd. This is useful for things like b/173037611. 40 } 41 flushnull42 override fun flush() { 43 fileOutputStream.flush() 44 } 45 } 46