Skip to content

Commit

Permalink
fixes
Browse files Browse the repository at this point in the history
  • Loading branch information
inputfalken committed Nov 16, 2024
1 parent 03c14bf commit 04262ff
Show file tree
Hide file tree
Showing 5 changed files with 12 additions and 5 deletions.
2 changes: 1 addition & 1 deletion src/Dynatello/Handlers/GetRequestHandler.cs
Original file line number Diff line number Diff line change
Expand Up @@ -39,7 +39,7 @@ Func<Dictionary<string, AttributeValue>, T> createItem
public async Task<T?> Send(TArg arg, CancellationToken cancellationToken)
{
var response = await _createRequest(arg)
.SendRequest<GetItemRequest, GetItemResponse>(
.SendRequest(
_options.RequestsPipelines,
(x, y, z) => y.GetItemAsync(x, z),
_options.AmazonDynamoDB,
Expand Down
2 changes: 1 addition & 1 deletion src/Dynatello/Handlers/PutRequestHandler.cs
Original file line number Diff line number Diff line change
Expand Up @@ -27,7 +27,7 @@ Func<Dictionary<string, AttributeValue>, T> createItem
{
var request = _createRequest(arg);

var response = await request.SendRequest<PutItemRequest, PutItemResponse>(
var response = await request.SendRequest(
_options.RequestsPipelines,
(x, y, z) => y.PutItemAsync(x, z),
_options.AmazonDynamoDB,
Expand Down
2 changes: 1 addition & 1 deletion src/Dynatello/Handlers/QueryRequestHandler.cs
Original file line number Diff line number Diff line change
Expand Up @@ -29,7 +29,7 @@ public async Task<IReadOnlyList<T>> Send(TArg arg, CancellationToken cancellatio
var list = new List<T>();
do
{
response = await request.SendRequest<QueryRequest, QueryResponse>(
response = await request.SendRequest(
_options.RequestsPipelines,
(x, y, z) => y.QueryAsync(x, z),
_options.AmazonDynamoDB,
Expand Down
2 changes: 1 addition & 1 deletion src/Dynatello/Handlers/UpdateRequestHandler.cs
Original file line number Diff line number Diff line change
Expand Up @@ -24,7 +24,7 @@ Func<Dictionary<string, AttributeValue>, T> unmarshall
public async Task<T?> Send(TArg arg, CancellationToken cancellationToken)
{
var request = _createRequest(arg);
var response = await request.SendRequest<UpdateItemRequest, UpdateItemResponse>(
var response = await request.SendRequest(
_options.RequestsPipelines,
(x, y, z) => y.UpdateItemAsync(x, z),
_options.AmazonDynamoDB,
Expand Down
9 changes: 8 additions & 1 deletion src/Dynatello/ITableAccess.cs
Original file line number Diff line number Diff line change
Expand Up @@ -17,10 +17,17 @@ namespace Dynatello;
/// <typeparam name="TArgumentReferences">
/// A type that represents the type param <typeparamref name="TArg"/> with AttributeExpression support.
/// </typeparam>
public interface ITableAccess<T, TArg, TReferences, TArgumentReferences>
public interface ITableAccess<T, in TArg, out TReferences, out TArgumentReferences>
where TReferences : IAttributeExpressionNameTracker
where TArgumentReferences : IAttributeExpressionValueTracker<TArg>
{
/// <summary>
/// Gets the Marshaller
/// </summary>
public IDynamoDBMarshaller<T, TArg, TReferences, TArgumentReferences> Marshaller { get; }

/// <summary>
/// Gets the table name
/// </summary>
public string TableName { get; }
}

0 comments on commit 04262ff

Please sign in to comment.