ExternalVendorCode/corda
1
0
Fork 0
mirror of https://github.com/corda/corda.git synced 2025-02-25 19:11:45 +00:00
Code Issues Actions 2 Packages Projects Releases Wiki Activity

Moved FlowSafeSubject under package node.internal as it is only used by NodeVaultService

Browse Source
This commit is contained in:
Kyriakos Tharrouniatis 2020-02-16 21:29:51 +00:00
parent d341a982a3
commit 17b94c45e8
3 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
core/src/main/kotlin/net/corda/core/utilities/FlowSafeSubject.kt → node/src/main/kotlin/net/corda/node/internal/FlowSafeSubject.kt
View File

@ -1,4 +1,4 @@
package net.corda.core.utilities package net.corda.node.internal
import net.corda.core.internal.FlowSafeSubscriber import net.corda.core.internal.FlowSafeSubscriber
import net.corda.core.internal.VisibleForTesting import net.corda.core.internal.VisibleForTesting

2
node/src/main/kotlin/net/corda/node/services/vault/NodeVaultService.kt
View File

@ -18,6 +18,8 @@ import net.corda.core.schemas.PersistentStateRef
import net.corda.core.serialization.SingletonSerializeAsToken import net.corda.core.serialization.SingletonSerializeAsToken
import net.corda.core.transactions.* import net.corda.core.transactions.*
import net.corda.core.utilities.* import net.corda.core.utilities.*
import net.corda.node.internal.FlowSafeSubject
import net.corda.node.internal.PreventSubscriptionsSubject
import net.corda.node.services.api.SchemaService import net.corda.node.services.api.SchemaService
import net.corda.node.services.api.VaultServiceInternal import net.corda.node.services.api.VaultServiceInternal
import net.corda.node.services.schema.PersistentStateService import net.corda.node.services.schema.PersistentStateService

2
node/src/test/kotlin/net/corda/node/utilities/ObservablesTests.kt
View File

@ -3,7 +3,7 @@ package net.corda.node.utilities
import com.google.common.util.concurrent.SettableFuture import com.google.common.util.concurrent.SettableFuture
import net.corda.core.internal.bufferUntilSubscribed import net.corda.core.internal.bufferUntilSubscribed
import net.corda.core.internal.tee import net.corda.core.internal.tee
import net.corda.core.utilities.FlowSafeSubject import net.corda.node.internal.FlowSafeSubject
import net.corda.core.internal.FlowSafeSubscriber import net.corda.core.internal.FlowSafeSubscriber
import net.corda.core.internal.OnNextFailedException import net.corda.core.internal.OnNextFailedException
import net.corda.nodeapi.internal.persistence.* import net.corda.nodeapi.internal.persistence.*