mirror of
https://github.com/digital-asset/daml.git
synced 2024-09-20 01:07:18 +03:00
Optimize imports in //language-support/java/bindings-rxjava (#3728)
This commit is contained in:
Stefano Baghino
mergify[bot]
parent
ba0c5e8b30
commit
50d689d011
@ -5,7 +5,6 @@ package com.daml.ledger.rxjava;
|
||||
|
||||
import com.daml.ledger.javaapi.data.Command;
|
||||
import com.google.protobuf.Empty;
|
||||
import com.google.protobuf.Timestamp;
|
||||
import io.reactivex.Single;
|
||||
import org.checkerframework.checker.nullness.qual.NonNull;
|
||||
|
||||
|
||||
@ -11,9 +11,7 @@ import io.grpc.netty.NettyChannelBuilder;
|
||||
import io.netty.handler.ssl.SslContext;
|
||||
import org.checkerframework.checker.nullness.qual.NonNull;
|
||||
|
||||
import java.util.LinkedList;
|
||||
import java.util.Optional;
|
||||
import java.util.concurrent.Callable;
|
||||
import java.util.concurrent.TimeUnit;
|
||||
|
||||
/**
|
||||
|
||||
@ -3,8 +3,8 @@
|
||||
|
||||
package com.daml.ledger.rxjava.components;
|
||||
|
||||
import com.daml.ledger.rxjava.components.helpers.*;
|
||||
import com.daml.ledger.javaapi.data.*;
|
||||
import com.daml.ledger.rxjava.components.helpers.*;
|
||||
import com.google.rpc.Status;
|
||||
import io.reactivex.Flowable;
|
||||
import io.reactivex.Single;
|
||||
|
||||
@ -3,8 +3,8 @@
|
||||
|
||||
package com.daml.ledger.rxjava.components.helpers;
|
||||
|
||||
import com.daml.ledger.javaapi.data.SubmitCommandsRequest;
|
||||
import com.daml.ledger.javaapi.data.Identifier;
|
||||
import com.daml.ledger.javaapi.data.SubmitCommandsRequest;
|
||||
import org.checkerframework.checker.nullness.qual.NonNull;
|
||||
import org.pcollections.HashTreePMap;
|
||||
import org.pcollections.PMap;
|
||||
|
||||
@ -7,7 +7,7 @@ import com.daml.ledger.javaapi.data.Identifier;
|
||||
import com.daml.ledger.javaapi.data.Record;
|
||||
import com.daml.ledger.javaapi.data.Template;
|
||||
import com.daml.ledger.javaapi.data.Value;
|
||||
import com.daml.ledger.rxjava.components.helpers.CreatedContract;
|
||||
|
||||
import java.lang.reflect.InvocationTargetException;
|
||||
import java.lang.reflect.Method;
|
||||
import java.util.HashMap;
|
||||
|
||||
@ -3,11 +3,11 @@
|
||||
|
||||
package com.daml.ledger.rxjava.grpc;
|
||||
|
||||
import com.daml.ledger.rxjava.CommandCompletionClient;
|
||||
import com.daml.ledger.javaapi.data.CompletionEndResponse;
|
||||
import com.daml.ledger.javaapi.data.CompletionStreamRequest;
|
||||
import com.daml.ledger.javaapi.data.CompletionStreamResponse;
|
||||
import com.daml.ledger.javaapi.data.LedgerOffset;
|
||||
import com.daml.ledger.rxjava.CommandCompletionClient;
|
||||
import com.daml.ledger.rxjava.grpc.helpers.StubHelper;
|
||||
import com.daml.ledger.rxjava.util.ClientPublisherFlowable;
|
||||
import com.digitalasset.grpc.adapter.ExecutionSequencerFactory;
|
||||
|
||||
@ -3,9 +3,9 @@
|
||||
|
||||
package com.daml.ledger.rxjava.grpc;
|
||||
|
||||
import com.daml.ledger.rxjava.CommandSubmissionClient;
|
||||
import com.daml.ledger.javaapi.data.Command;
|
||||
import com.daml.ledger.javaapi.data.SubmitRequest;
|
||||
import com.daml.ledger.rxjava.CommandSubmissionClient;
|
||||
import com.daml.ledger.rxjava.grpc.helpers.StubHelper;
|
||||
import com.digitalasset.ledger.api.v1.CommandSubmissionServiceGrpc;
|
||||
import com.digitalasset.ledger.api.v1.CommandSubmissionServiceOuterClass;
|
||||
|
||||
@ -3,8 +3,8 @@
|
||||
|
||||
package com.daml.ledger.rxjava.grpc;
|
||||
|
||||
import com.daml.ledger.rxjava.TransactionsClient;
|
||||
import com.daml.ledger.javaapi.data.*;
|
||||
import com.daml.ledger.rxjava.TransactionsClient;
|
||||
import com.daml.ledger.rxjava.util.ClientPublisherFlowable;
|
||||
import com.digitalasset.grpc.adapter.ExecutionSequencerFactory;
|
||||
import com.digitalasset.ledger.api.v1.TransactionServiceGrpc;
|
||||
|
||||
@ -9,7 +9,6 @@ import java.util.concurrent.TimeUnit
|
||||
import com.daml.ledger.javaapi.data.LedgerOffset.Absolute
|
||||
import com.daml.ledger.javaapi.data.{Command, CreateCommand, Identifier, Record}
|
||||
import com.daml.ledger.rxjava.grpc.helpers.{CommandServiceImpl, _}
|
||||
import com.daml.ledger.testkit.services._
|
||||
import com.digitalasset.ledger.api.v1.command_completion_service.CompletionStreamResponse
|
||||
import com.digitalasset.ledger.api.v1.command_service.{
|
||||
SubmitAndWaitForTransactionIdResponse,
|
||||
|
||||
@ -3,15 +3,14 @@
|
||||
|
||||
package com.daml.ledger.rxjava.components
|
||||
|
||||
import com.daml.ledger.javaapi.data.Identifier
|
||||
import com.daml.ledger.javaapi.data.Party
|
||||
import com.daml.ledger.javaapi.data.Record
|
||||
import com.daml.ledger.javaapi.data.Text
|
||||
import com.daml.ledger.rxjava.components.helpers.CreatedContract
|
||||
import com.daml.ledger.rxjava.components.helpers.CreatedContractContext
|
||||
import com.daml.ledger.rxjava.components.helpers.TemplateUtils
|
||||
import templateutils.{TemplateA, TemplateB, TemplateC}
|
||||
import com.daml.ledger.javaapi.data.{Identifier, Party, Record, Text}
|
||||
import com.daml.ledger.rxjava.components.helpers.{
|
||||
CreatedContract,
|
||||
CreatedContractContext,
|
||||
TemplateUtils
|
||||
}
|
||||
import org.scalatest.{FlatSpec, Matchers}
|
||||
import templateutils.{TemplateA, TemplateB, TemplateC}
|
||||
|
||||
class TestContext extends CreatedContractContext {
|
||||
@Override
|
||||
|
||||
@ -5,8 +5,8 @@ package com.daml.ledger.rxjava.components
|
||||
|
||||
import java.util.concurrent.TimeUnit
|
||||
|
||||
import com.daml.ledger.rxjava.components.helpers.{CommandsAndPendingSet, CreatedContract}
|
||||
import com.daml.ledger.javaapi.data.{Identifier, LedgerOffset, WorkflowEvent}
|
||||
import com.daml.ledger.rxjava.components.helpers.{CommandsAndPendingSet, CreatedContract}
|
||||
import io.reactivex.Flowable
|
||||
import org.scalatest.{FlatSpec, Matchers}
|
||||
|
||||
|
||||
@ -6,8 +6,8 @@ package com.daml.ledger.rxjava.components.tests.helpers
|
||||
import java.time.Instant
|
||||
import java.util
|
||||
|
||||
import com.daml.ledger.rxjava._
|
||||
import com.daml.ledger.javaapi.data._
|
||||
import com.daml.ledger.rxjava._
|
||||
import com.google.protobuf.Empty
|
||||
import io.reactivex.{Flowable, Single}
|
||||
import org.slf4j.LoggerFactory
|
||||
|
||||
@ -7,13 +7,7 @@ import java.time.Instant
|
||||
import java.util.concurrent.TimeUnit
|
||||
|
||||
import com.daml.ledger.rxjava.TimeClient
|
||||
import com.daml.ledger.rxjava.grpc.helpers.{
|
||||
AuthMatchers,
|
||||
DataLayerHelpers,
|
||||
LedgerServices,
|
||||
TestConfiguration,
|
||||
TimeServiceImpl
|
||||
}
|
||||
import com.daml.ledger.rxjava.grpc.helpers._
|
||||
import org.scalatest.{FlatSpec, Matchers, OptionValues}
|
||||
|
||||
import scala.concurrent.ExecutionContext
|
||||
|
||||
@ -7,8 +7,8 @@ import java.time.Instant
|
||||
|
||||
import com.daml.ledger.javaapi.data._
|
||||
import com.digitalasset.ledger.api.v1.active_contracts_service.GetActiveContractsResponse
|
||||
import com.digitalasset.ledger.api.v1.event.CreatedEvent
|
||||
import com.digitalasset.ledger.api.v1.command_completion_service.CompletionEndResponse
|
||||
import com.digitalasset.ledger.api.v1.event.CreatedEvent
|
||||
import com.digitalasset.ledger.api.v1.ledger_offset.LedgerOffset
|
||||
import com.digitalasset.ledger.api.v1.ledger_offset.LedgerOffset.Value.Absolute
|
||||
import com.digitalasset.ledger.api.v1.testing.time_service.GetTimeResponse
|
||||
|
||||
@ -3,12 +3,12 @@
|
||||
|
||||
package com.daml.ledger.rxjava.grpc.helpers
|
||||
|
||||
import com.digitalasset.ledger.api.v1.ledger_configuration_service.LedgerConfigurationServiceGrpc.LedgerConfigurationService
|
||||
import com.digitalasset.ledger.api.v1.ledger_configuration_service.{
|
||||
GetLedgerConfigurationRequest,
|
||||
GetLedgerConfigurationResponse,
|
||||
LedgerConfigurationServiceGrpc
|
||||
}
|
||||
import com.digitalasset.ledger.api.v1.ledger_configuration_service.LedgerConfigurationServiceGrpc.LedgerConfigurationService
|
||||
import io.grpc.ServerServiceDefinition
|
||||
import io.grpc.stub.StreamObserver
|
||||
|
||||
|
||||
@ -5,12 +5,12 @@ package com.daml.ledger.rxjava.grpc.helpers
|
||||
|
||||
import com.digitalasset.ledger.api.auth.Authorizer
|
||||
import com.digitalasset.ledger.api.auth.services.LedgerIdentityServiceAuthorization
|
||||
import com.digitalasset.ledger.api.v1.ledger_identity_service.LedgerIdentityServiceGrpc.LedgerIdentityService
|
||||
import com.digitalasset.ledger.api.v1.ledger_identity_service.{
|
||||
GetLedgerIdentityRequest,
|
||||
GetLedgerIdentityResponse,
|
||||
LedgerIdentityServiceGrpc
|
||||
}
|
||||
import com.digitalasset.ledger.api.v1.ledger_identity_service.LedgerIdentityServiceGrpc.LedgerIdentityService
|
||||
import io.grpc.ServerServiceDefinition
|
||||
|
||||
import scala.concurrent.{ExecutionContext, Future}
|
||||
|
||||
@ -5,13 +5,12 @@ package com.daml.ledger.rxjava.grpc.helpers
|
||||
|
||||
import java.time.Instant
|
||||
|
||||
import com.daml.ledger.rxjava.grpc.helpers.Generators._
|
||||
import com.google.protobuf.Timestamp
|
||||
import org.scalacheck.Gen
|
||||
import org.scalatest.prop.GeneratorDrivenPropertyChecks
|
||||
import org.scalatest.{FlatSpec, Matchers}
|
||||
|
||||
import Generators._
|
||||
|
||||
class TimestampComparatorTest extends FlatSpec with Matchers with GeneratorDrivenPropertyChecks {
|
||||
|
||||
behavior of "TimestampComparator.compare"
|
||||
|
||||
@ -7,16 +7,7 @@ import java.time.Clock
|
||||
import java.util.UUID
|
||||
|
||||
import com.digitalasset.daml.lf.data.Ref
|
||||
import com.digitalasset.ledger.api.auth.{
|
||||
AuthServiceStatic,
|
||||
Authorizer,
|
||||
Claim,
|
||||
ClaimActAsParty,
|
||||
ClaimAdmin,
|
||||
ClaimPublic,
|
||||
ClaimReadAsParty,
|
||||
Claims
|
||||
}
|
||||
import com.digitalasset.ledger.api.auth._
|
||||
|
||||
package object grpc {
|
||||
|
||||
|
||||
Loading…
Reference in New Issue
Block a user